package com.ngkj.zmfptes.util;

import com.ngkj.zmfptCommon.common.bean.RpcRequestMessage;
import com.ngkj.zmfptCommon.common.util.SerializeUtil;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * @author ChenHN
 * @since 2021/11/15 creation
 **/
public class RpcRequestDeseralizer implements Deserializer<RpcRequestMessage> {

    //反序列化
    @Override
    public RpcRequestMessage deserialize(String s, byte[] bytes) {
        return (RpcRequestMessage) SerializeUtil.deserialize(bytes, RpcRequestMessage.class);
    }
}
